package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.SmsBinderConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * 短信 消息队列
 * @author 魏荣杰
 * @date 2019/3/19 15:24
 * @since v1.0
 * @version v1.0
 */
@Service("smsConsumerBinder")
public interface SmsConsumerBinder {

    /**
     *  短信 消息队列
     */
    @Input(SmsBinderConstant.SMS_INPUT)
    SubscribableChannel smsInput();
//    @Output(SmsBinderConstant.SMS_OUTPUT)
//    MessageChannel smsOutput();

}
